# -*- coding: utf-8 -*-
# standard
import os
import sys

# third
from celery import Celery

# local
_P_PATH = os.path.dirname(os.path.realpath(__file__))
if _P_PATH not in sys.path:
    sys.path.append(_P_PATH)
from functions.periodic_func import *



"""
@Title:   
@File: main_worker.py
@Author: walle 2024年12日29日 07时09分10秒
@Version: 1.0.0
@Desc: 
"""


def purge_all_tasks():
    """
    清空所有任务
    """
    CELERY_APP.control.discard_all()
    CELERY_APP.control.purge()



if __name__ == '__main__':
    purge_all_tasks()
    pass